cb0d432f358615b12a65eb62f4b03b70680b3575,modules/mqtt/src/main/java/org/apache/ignite/stream/mqtt/MqttStreamer.java,MqttStreamer,start,#,147
Before Change
A.ensure(qualitiesOfService.isEmpty() || qualitiesOfService.size() == topics.size(), "qualities of " +
"service must be either empty or have the same size as topics list");
cachedLogPrefix = "[" + Joiner.on(",").join(topics) + "]";
}
else { // just the single topic
topics.add(topic);
After Change
logValues.put("clientId", clientId);
// cache log values
cachedLogValues = "[" + Joiner.on(", ").withKeyValueSeparator("=").join(logValues) + "]";
// create logger
log = getIgnite().log();